package com.spx.chapter05.sink;

import com.spx.chapter05.pojo.Event;
import com.spx.util.SampleDataUtil;
import org.apache.flink.configuration.Configuration;
import org.apache.flink.streaming.api.datastream.DataStreamSource;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
import org.apache.flink.streaming.api.functions.sink.RichSinkFunction;
import org.apache.flink.streaming.api.functions.sink.SinkFunction;

/**
 * create by undeRdoG on  2022-05-01  16:22
 * 凡心所向，素履以往，生如逆旅，一苇以航。
 */
public class CustomSinkTest_Hbase {

    public static void main(String[] args) {
        StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();

        DataStreamSource<Event> dataSource = env.fromCollection(SampleDataUtil.getSample());




    }



    public static class HbaseSinkConnector extends RichSinkFunction<Event> {

        @Override
        public void invoke(Event value, Context context) throws Exception {

        }


        @Override
        public void open(Configuration parameters) throws Exception {
            super.open(parameters);
        }

        @Override
        public void close() throws Exception {
            super.close();
        }
    }

}
